package flinkstudy.stream.source;

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.junit.Before;

/**
 * @author daocr
 * @date 2019/12/14
 */
public class BaseTest {

    StreamExecutionEnvironment env = null;

    @Before
    public void init() {
        env = StreamExecutionEnvironment.getExecutionEnvironment();
        ExecutionEnvironment.getExecutionEnvironment();
    }


}
